package com.venus.kafka.producer.rest;

import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.google.gson.JsonObject;
import com.venus.kafka.producer.service.ProducerService;

/**
 * @author lwl
 * @date 2020/9/1 17:58
 */
@RestController("/producer")
public class ProducerRest {

	@Autowired
	private ProducerService producerService;

	@RequestMapping("/produce")
	public JsonObject produce(Map<String, String> param) {

		JsonObject object = new JsonObject();
		producerService.sendMessage();
		return object;

	}

}
